4b6918a3f06e5e5fb3987cde68734fc2225f54d8,core/src/main/java/tachyon/hadoop/AbstractTFS.java,AbstractTFS,create,#Path#FsPermission#boolean#number#number#number#Progressable#,75
Before Change
}
if (cPath.toString().contains(FIRST_COM_PATH) && !cPath.toString().contains("SUCCESS")) {
String pathWithoutScheme = Utils.getPathWithoutScheme(cPath);
TachyonURI path = new TachyonURI(pathWithoutScheme);
mTFS.createFile(path, blockSize);
String depPath = path.getPath();
depPath = depPath.substring(depPath.indexOf(FIRST_COM_PATH) + FIRST_COM_PATH.length());
After Change
+ replication + ", " + blockSize + ", " + progress + ")");
if (!CommonConf.get().ASYNC_ENABLED) {
TachyonURI path = new TachyonURI(Utils.getPathWithoutScheme(cPath));
if (mTFS.exist(path)) {
if (!mTFS.delete(path, false)) {
throw new IOException("Failed to delete existing data " + cPath);
}
}
int fileId = mTFS.createFile(path, blockSize);
TachyonFile file = mTFS.getFile(fileId);
file.setUFSConf(getConf());
return new FSDataOutputStream(file.getOutStream(WriteType.CACHE_THROUGH), null);
}
if (cPath.toString().contains(FIRST_COM_PATH) && !cPath.toString().contains("SUCCESS")) {
TachyonURI path = new TachyonURI(Utils.getPathWithoutScheme(cPath));
mTFS.createFile(path, blockSize);
String depPath = path.getPath();
depPath = depPath.substring(depPath.indexOf(FIRST_COM_PATH) + FIRST_COM_PATH.length());